package com.cn.task;

import com.cn.service.RunLogService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.ApplicationListener;
import org.springframework.context.event.ContextRefreshedEvent;
import org.springframework.data.mongodb.core.MongoTemplate;
import org.springframework.stereotype.Component;

import java.util.concurrent.ConcurrentHashMap;

/**
 * Created by chenyuncong on 2018/8/6.
 */

public abstract class Consumer extends Thread {

    final ConcurrentHashMap<String,Object> countMap = new ConcurrentHashMap<>();

    @Override
    public abstract void run();
}
